package streamforce.crypto.event;

import java.util.HashMap;
import java.util.Map;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import streamforce.crypto.KPAbe;

/**
 * This is the output stream after transforming the deterministic encryption
 * Used for Join
 */
public class StockEventJoin extends AbstractEvent{
	private final Log log = LogFactory.getLog(StockEventJoin.class);
	private Map<String, Ciphertext> price, volume;		
		

	public StockEventJoin(int ts, int hour, int sid, Map<String, Ciphertext> price,
			Map<String, Ciphertext> volume) {
		super(ts,hour,sid);
		this.price = price;
		this.volume = volume;		
	}

	public int getTimestamp() {
		return timestamp;
	}


	public void setTimestamp(int timestamp) {
		this.timestamp = timestamp;
	}


	public int getStockId() {
		return stockId;
	}


	public void setStockId(int stockId) {
		this.stockId = stockId;
	}
	
	public Ciphertext getPrice(String val){
		return price.get(val);
	}

	public Map<String, Ciphertext> getPrice() {
		return price;
	}


	public void setPrice(Map<String, Ciphertext> price) {
		this.price = price;
	}

	public Ciphertext getVolume(String val){
		return this.volume.get(val);
	}

	public Map<String, Ciphertext> getVolume() {
		return volume;
	}


	public void setVolume(Map<String, Ciphertext> volume) {
		this.volume = volume;
	}


	public Log getLog() {
		return log;
	}

	
	
}
